package wanda.cnstants

object Constants {

  /**
    * topo 初始化参数
    */

  val TOPICS: String = "spark.topo.topics"

  val BROKERS: String = "spark.topo.brokers"

  val CLASS_NAME: String = "spark.topo.name"

  val DURATION: String = "spark.topo.duration.second"

  val LOG_LEVEL: String = "spark.topo.log.level"

  val OFFSETSPERTRIGGER: String = "spark.OffsetsPerTrigger.count"

  val INTERVAL: String = "spark.interval"

  val CHECKPOINTPATH: String = "spark.checkpointLocation.path"

  val LOCATIONPATH: String = "spark.localtion.path"

  val PRIMARYKEY: String = "spark.primaryKey"

  val PARTITION: String = "spark.partition"
  val DELETEMODE:String= "spark.delete.partition"

  val RANGE: String = "spark.rang"

}
